package com.ruoyi.iot.service;

import com.ruoyi.iot.domain.IotDataWaterPressureInfo;
import com.ruoyi.iot.domain.IotSensorMsg;

import java.util.List;
import java.util.Map;

public interface IIotSensorCollectService {
    Boolean saveToInfluxDB(String measurement, Map<String, String> tags, Map<String, Object> fields);
    Boolean saveToInfluxDB(Long timestamp, String measurement, Map<String, String> tags, Map<String, Object> fields);
    List<Map<String, Object>> queryList(Map<String, Object> params);

    Boolean saveToMysql(String tableName, Map<String, String> tags, Map<String, Object> stringObjectMap);

    Boolean batchSaveToMysql(String tableName, List<Map<String, Object>> batchData);
    String queryRemoteIdBYSensorId(String s);

    Boolean batchSaveToInfluxDB(String measurement, List<Map<String, Object>> batchData);

    String geSensorIdByRemoteIdANDFuncCode(String remoteId, String funcCode);

    void saveSensorMsg(IotSensorMsg build);

    Map<String, IotDataWaterPressureInfo> getAllPressureInfo();
}
